package cn.wzy.rocketmq.service;

public interface IRocketMqService {

    //同步发送  哪怕是对象也通过fastjson转换为字符串在发送
    void sendMsg(String msg, String topic, String tag);

    void sendMsg(String msg, String topic);

    //异步发送
    void sendAsyncMsg(String msg, String topic, String tag);

    void sendAsyncMsg(String msg, String topic);

    //延时发送
    void sendDelayMsg(String msg, String topic, String tag, int delayLevel);

    void sendDelayMsg(String msg, String topic, int delayLevel);


    //发送事务消息
    void sendTransMsg(String txProducerGroup,String msg, String topic);
    void sendTransMsg(String txProducerGroup,String msg, String topic,String tag);
}